package com.example.capsule_netty.configuration;

/**
 * @Author: zhuzhiming
 * @Date: 2022/5/4 18:15
 */
public class KafkaConstant {

    public static final String DELETE_MESSAGE_TOPIC = "deleteMessageTopic";
    public static final String SAVE_MESSAGE_TOPIC = "saveMessageTopic";
    public static final String USER_TOPIC = "userTopic";
    public static final String ES_DOC_INSERT_TOPIC = "esDocInsertTopic";
    public static final String ES_DOC_UPDATE_TOPIC = "esDocUpdateTopic";
    public static final String ES_DOC_DELETE_TOPIC = "esDocDeleteTopic";
    public static final String POSITION_TOPIC = "positionTopic";


}
